// 
// Notice Regarding Standards.  AMD does not provide a license or sublicense to
// any Intellectual Property Rights relating to any standards, including but not
// limited to any audio and/or video codec technologies such as MPEG-2, MPEG-4;
// AVC/H.264; HEVC/H.265; AAC decode/FFMPEG; AAC encode/FFMPEG; VC-1; and MP3
// (collectively, the "Media Technologies"). For clarity, you will pay any
// royalties due for such third party technologies, which may include the Media
// Technologies that are owed as a result of AMD providing the Software to you.
// 
// MIT license 
// 
// Copyright (c) 2018 Advanced Micro Devices, Inc. All rights reserved.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
//
#pragma once

#include "PipelineElement.h"
#include <vector>

enum PipelineState
{
    PipelineStateNotReady,
    PipelineStateReady,
    PipelineStateRunning,
    PipelineStateFrozen,
    PipelineStateEof,
};
enum ConnectionThreading
{
    CT_ThreadQueue,
    CT_ThreadPoll,
    CT_Direct,
};

class PipelineConnector;
class Pipeline
{
    friend class PipelineConnector;
    typedef std::shared_ptr<PipelineConnector> PipelineConnectorPtr;
public:
    Pipeline();
    virtual ~Pipeline();

    AMF_RESULT Connect(PipelineElementPtr pElement, amf_int32 queueSize, ConnectionThreading eThreading = CT_ThreadQueue);
    AMF_RESULT Connect(PipelineElementPtr pElement, amf_int32 slot, PipelineElementPtr upstreamElement, amf_int32 upstreamSlot, amf_int32 queueSize, ConnectionThreading eThreading = CT_ThreadQueue);
    AMF_RESULT SetStatSlot(PipelineElementPtr pElement, amf_int32 slot);

    virtual AMF_RESULT      Start();
    virtual AMF_RESULT      Stop();
    virtual AMF_RESULT      Restart();

    virtual PipelineState   GetState() const;

    virtual void            DisplayResult();
    virtual double          GetFPS();
    double                  GetProcessingTime();
    amf_int64               GetNumberOfProcessedFrames();

protected:
    virtual AMF_RESULT      Freeze();
    virtual AMF_RESULT      UnFreeze();
    virtual AMF_RESULT      Flush();

    virtual void            OnEof();

    amf_int64                           m_startTime;
    amf_int64                           m_stopTime;

    typedef std::vector<PipelineConnectorPtr> ConnectorList;
    ConnectorList                       m_connectors;
    PipelineState                       m_state;
    mutable amf::AMFCriticalSection     m_cs;
};